//package com.github.llyb120.driver.qiuya;
//
//import com.github.llyb120.json.Json;
//import com.github.llyb120.json.Obj;
//
//public class WebSocketDealHandler implements Runnable{
//
//    private WebSocket webSocket;
//
//    public WebSocketDealHandler(WebSocket webSocket) {
//        this.webSocket = webSocket;
//    }
//
//    @Override
//    public void run() {
//        try {
//            did();
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        }
//    }
//
//    public void did() throws InterruptedException {
//        while(true){
//            WebSocket.Message msg = webSocket.dealQueue.take();
//            //是否有这个线程的回调
//            WebSocket.Message source = webSocket.acks.get(msg.ack);
//            if (source == null) {
//                continue;
//            }
//            Obj obj = Json.parse(msg.content);
//            if (obj == null) {
//                return;
//            }
//            source.result = obj;
////                try{
////                    lock.lock();
//            //清理map
////                    acks.remove(msg.ack);
//            //返回结果
//            source.cd.countDown();
////                    source.condition.signal();
////                } finally {
////                    lock.unlock();
////                }
//        }
//    }
//
//}
